package com.liuyi.netty.im.server.handle.cluster.impl;

import com.liuyi.netty.im.commons.codes.data.DataEvent;
import com.liuyi.netty.im.server.handle.message.SendMessageProcessor;

import java.util.concurrent.ThreadPoolExecutor;

/**
 * 集群发送默认实现类
 *
 * @author Mr.Fmy
 * @since 2021/12/25
 */
public class DefaultClusterSend extends AbstractClusterSend {


    public DefaultClusterSend(SendMessageProcessor sendMessageProcessor, ThreadPoolExecutor threadPoolExecutor) {
        super(sendMessageProcessor, threadPoolExecutor);
    }

    @Override
    public void broadcast(DataEvent data) {
        accept(data);
    }
}
